package com.feng.d18Segregation;

/**
 * Redis的配置类,本体是没有实现任何接口,但是为了业务(详情看introduce)要求1,我们需要实现Update接口
 * @author LiYilin on 2020/4/13
 */
public class KafkaConfig implements Update{

    /**
     * 配置中心,如zookeeper
     */
    private ConfigSource configSource;
    private String address;
    private int timeout;
    private int maxTotal;
    //其他相关配置...

    public KafkaConfig(ConfigSource configSource) {
        this.configSource = configSource;
    }

    public String getAddress() {
        return this.address;
    }
    //...省略其他get()、init()方法...

    /**
     * 从configSource加载配置到address/timeout/maxTotal...
     * 原本的类中就有此方法,在实现需求1时,我们把这个方法抽象到Update接口中添加@Override注解
     */
    @Override
    public void update() {
        //从configSource加载配置到address/timeout/maxTotal...
    }
}
